﻿using EventBus.Common;
using System;
using System.Collections.Generic;
using System.Text;
using System.Threading.Tasks;

namespace EventBus.Kafka
{
   public interface IKafkaSubscriber
    {
        Task SubscriberCommand<TCommand>(IServiceProvider serviceProvider, string topic, string groupId) where TCommand : ICommand;
    }
}
